package cn.com.cmbc;

import cn.com.cmbc.service.FileKafkaService;

/**
 * Hello world!
 *
 */
public class App 
{
    public static void main( String[] args )
    {
        System.out.println( "Hello World!" );

        //获取Kafka数据为 KakfaDAOList
        String topic = "diskfile";
        FileKafkaService fileKafkaService = new FileKafkaService();
        fileKafkaService.getKafkaData();


        //将kafka数据转换为ESDAOList

        //将ESDAOList数据写入ES


    }
}
